package cn.lcsjsxy.yxc.io;

import org.junit.jupiter.api.Test;

import java.io.*;

/**
 * 处理流之一：缓冲流的使用
 *
 * 1.缓冲流：
 * BufferedInputStream
 * BufferedOutputStream
 * BufferedReader
 * BufferedWriter
 *
 * 2.作用：提供流的读取、写入的速度
 * 提高读写速度的原因：内部提供了一个缓冲区
 *
 * 3.处理流，就是“套接”在已有的流的基础上
 */

public class BufferedTest {

    /*
    * 实现非文本文件的复制
    * */
    @Test
    public void bufferedStreamTest(){
        FileInputStream fis=null;
        FileOutputStream fos=null;
        BufferedInputStream bis=null;
        BufferedOutputStream bos=null;

        try {
            //1.造文件
            File stcFile = new File("婉茗.jpg");
            File destFile = new File("婉茗copy.jpg");

            //2.造流
            //2.1造节点流
            fis=new FileInputStream(stcFile);
            fos=new FileOutputStream(destFile);

            //2.2造缓冲流
            bis = new BufferedInputStream(fis);
            bos = new BufferedOutputStream(fos);

            //3.复制的细节：读取、写入
            byte[] buffer = new byte[10];
            int len;
            while ((len = bis.read(buffer))!=-1){
                bos.write(buffer,0,len);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //4.资源关闭
            //要求：先关闭外层的流，再关闭内层的流
            //说明：关闭外层流的同时，内层流也会自动的进行关闭。关于内层流的关闭，我们可以省略。
            try {
                if (bis!=null){
                    bis.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }

            try {
                if (bos!=null){
                    bos.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    //实现文件复制的方法
    public void copyFileWithBuffered(String srcPath,String destPath){
        FileInputStream fis=null;  //节点流
        FileOutputStream fos=null;
        BufferedInputStream bis=null;  //缓冲流
        BufferedOutputStream bos=null;

        try {
            File file = new File(srcPath);
            File copyFile=new File(destPath);

            fis=new FileInputStream(file);
            fos=new FileOutputStream(copyFile);
            bis=new BufferedInputStream(fis);
            bos=new BufferedOutputStream(fos);

            byte[] buffer=new byte[1024];
            int len;
            while ((len=bis.read(buffer))!=-1){
                bos.write(buffer,0,len);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (bis!=null)
                    bis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }

            try {
                if (bos!=null)
                    bos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    @Test
    public void testCopyFileWithBufferd(){

        long start = System.currentTimeMillis();

        String srcPath = "C:\\Users\\13964\\Pictures\\NSHM_PHOTO\\婉茗.avi";
        String destPath = "C:\\Users\\13964\\Pictures\\NSHM_PHOTO\\婉茗copy.avi";

        copyFileWithBuffered(srcPath,destPath);

        long end =System.currentTimeMillis();

        System.out.println("复制操做花费的时间为:"+(end-start));

    }

    //BufferedReader和BufferedWriter的使用
    @Test
    public void testBufferedReaderBufferedWriter(){
        BufferedReader br=null;
        BufferedWriter bw=null;
        try {
            br=new BufferedReader(new FileReader(new File("hello.txt")));
            bw=new BufferedWriter(new FileWriter(new File("helloCopy.txt")));

            //读写操做
            //方式一：使用char[]数组
//            char[] cbuf=new char[1024];
//            int len;
//            while ((len=br.read(cbuf))!=-1){
//                bw.write(cbuf,0,len);
//            }

            //方式二：使用String
            String data;
            while ((data=br.readLine())!=null){
                //方法一：
//                bw.write(data+"\n");  //data中不包含换行符

                //方法二：
                bw.write(data);  //data中不包含换行符
                bw.newLine();  //提供换行的操做
            }

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (br!=null)
                   br.close();
            } catch (IOException e) {
                e.printStackTrace();
            }

            try {
                if (bw!=null)
                    bw.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
